package main;

import org.openjdk.jmh.annotations.Level;
import org.openjdk.jmh.annotations.Setup;
import threadPool.disruptor.DisruptorSingleExecutor;
import threadPool.IMessageExecutor;

import java.util.Queue;

/** Created by JinMiao 2020/5/20. */
public class KcpThreadBenchmark {

  public static final int PRODUCER_THREADS_NUMBER = 4;
  private Queue<Long> recieveList;
  private IMessageExecutor iMessageExecutor;

  @Setup(Level.Trial)
  public void setUp() {
    iMessageExecutor = new DisruptorSingleExecutor("");
    // recieveList = new SpscArrayQueue<>(2<<11);

  }
}
